package com.jvxb.demo.service;

import java.util.Set;

/**
 * @author jvxb
 * @since 2023-01-15
 */
public interface KafkaService {

    void send(String topic, String message);

    Set<String> listTopics() throws Exception;

}
